package hamster.csustef.acquisition.schema;

import org.apache.flink.api.common.serialization.SimpleStringSchema;

public class MySimpleStringSchema extends SimpleStringSchema {
    @Override
    public boolean isEndOfStream(String nextElement) {
        return "CLOSE".equals(nextElement);
    }
}
